51097fff4255160259c693b3c8ec52132c2ec15a,src/test/java/com/axibase/collector/logback/LogbackMessageWriterTest.java,LogbackMessageWriterTest,testBuildMultipleStatMessage,#,50
Before Change
{
catcher.clear();
events.clear();
messageBuilder.writeStatMessages(catcher, events);
String result = catcher.sb.toString();
assertTrue(result.contains("ERROR"));
assertTrue(result.contains("WARN"));
After Change
}
public void testBuildMultipleStatMessage() throws Exception {
LogbackMessageWriter<ILoggingEvent> messageBuilder = createMessageBuilder();
messageBuilder.setSeriesSenderConfig(new SeriesSenderConfig(1, 30, -1));
ArrayList<ILoggingEvent> events = new ArrayList<ILoggingEvent>();
for (int i = 0; i < 100; i++) {
events.add(TestUtils.createLoggingEvent(Level.ERROR, "test-logger", "test-message", "test-thread"));
events.add(TestUtils.createLoggingEvent(Level.WARN, "test-logger", "test-message", "test-thread"));
events.add(TestUtils.createLoggingEvent(Level.DEBUG, "test-logger", "test-message", "test-thread"));
}
StringsCatcher catcher;
{
catcher = new StringsCatcher();
messageBuilder.writeStatMessages(catcher, events, 60000);
String result = catcher.sb.toString();
System.out.println("result = " + result);
assertTrue(
result.contains("series e:test-entity t:ttt1=vvv1 t:ttt2=vvv2 m:test-metric_rate=100.0 t:level="));
assertTrue(result.contains("ERROR"));
assertTrue(result.contains("WARN"));
assertTrue(result.contains("DEBUG"));
assertTrue(result.contains("m:test-metric_rate=100.0 "));
assertTrue(result.contains("m:test-metric_total_rate=100.0 "));
assertTrue(result.contains("m:test-metric_total_counter=100 "));
}
{
catcher.clear();
events.clear();
events.add(TestUtils.createLoggingEvent(Level.ERROR, "test-logger", "test-message", "test-thread"));
messageBuilder.writeStatMessages(catcher, events, 60000 );
String result = catcher.sb.toString();
System.out.println("result = " + result);
assertTrue(result.contains("ERROR"));
assertTrue(result.contains("WARN"));
assertTrue(result.contains("DEBUG"));
assertTrue(result.contains("m:test-metric_rate=0.0"));
assertTrue(result.contains("m:test-metric_rate=1.0"));
assertTrue(result.contains("m:test-metric_total_rate=0.0"));
assertTrue(result.contains("m:test-metric_total_rate=1.0"));
assertTrue(result.contains("m:test-metric_total_counter=100"));
assertTrue(result.contains("m:test-metric_total_counter=101"));
}
{
catcher.clear();
events.clear();
messageBuilder.writeStatMessages(catcher, events, 60000);
String result = catcher.sb.toString();
assertTrue(result.contains("ERROR"));
assertFalse(result.contains("WARN"));